package drds.data_propagate.sink;

import drds.data_propagate.binlog_event_filter.BinlogEventFilter;
import drds.data_propagate.common.AbstractLifeCycle;
import lombok.Getter;
import lombok.Setter;

import java.util.ArrayList;
import java.util.List;


public abstract class AbstractEventListSink<T> extends AbstractLifeCycle implements EventListSink<T> {
    @Setter
    @Getter
    protected BinlogEventFilter binlogEventFilter;
    @Setter
    @Getter
    protected List<EventDownStreamHandler> eventDownStreamHandlerList = new ArrayList<EventDownStreamHandler>();

    public void addHandler(EventDownStreamHandler eventDownStreamHandler) {
        this.eventDownStreamHandlerList.add(eventDownStreamHandler);
    }

    public void interrupt() {
        // do nothing
    }

}
